package com.lecture.java8.geekbang.demo06;

public class KafkaConfig implements Updater {

    //配置中心 如zookeeper
    private String configSource;

    private String address;

    private int timeout;

    private int maxTotal;


    public KafkaConfig(String configSource) {
        this.configSource = configSource;
    }

    @Override
    public void update() {
        //从configSource加载配置到address、timeout等
    }
}
